#include <logging/log_message_test.hpp>

#include <map>
#include <numeric>
#include <set>
#include <stdexcept>
#include <unordered_map>
#include <unordered_set>

#include <gmock/gmock.h>
#include <gtest/gtest.h>
#include <boost/filesystem/path.hpp>

#include <logging/logging_test.hpp>
#include <logging/rate_limit.hpp>
#include <userver/decimal64/decimal64.hpp>
#include <userver/formats/json/serialize.hpp>
#include <userver/logging/impl/mem_logger.hpp>
#include <userver/logging/null_logger.hpp>
#include <userver/utils/regex.hpp>
#include <userver/utils/traceful_exception.hpp>
#include <utils/encoding/tskv_testdata_bin.hpp>

USERVER_NAMESPACE_BEGIN

namespace {

template <typename T>
std::string ToStringViaStreams(const T& value) {
    std::ostringstream oss;
    oss << value;
    return oss.str();
}

void CheckModulePath(std::string_view message, std::string_view expected) {
    auto module_pos = message.find("module=");
    ASSERT_NE(std::string::npos, module_pos) << "no module logged";
    auto path_pos = message.find(std::string{expected} + ':', module_pos);
    auto delim_pos = message.find('\t', module_pos);
    ASSERT_LT(path_pos, delim_pos) << "module mismatch, expected path '" << expected << "', found '"
                                   << message.substr(module_pos, delim_pos - module_pos) << '\'';
}

struct CountingStruct {
    mutable uint64_t logged_count = 0;

    friend logging::LogHelper& operator<<(logging::LogHelper& lh, [[maybe_unused]] const CountingStruct& self) {
        ++self.logged_count;
        return lh << "(CountingStruct)";
    }
};

template <int LogAttempts>
int CountLimitedLoggedTimes() {
    const CountingStruct cs;
    for (int i = 0; i < LogAttempts; ++i) {
        LOG_LIMITED_CRITICAL() << cs;
    }
    return cs.logged_count;
}

}  // namespace

TEST_F(LoggingTest, TskvEncode) {
    EXPECT_EQ(ToStringViaLogging("line 1\nline 2"), "line 1\\nline 2") << "escaped sequence is present in the message";
}

TEST_F(LoggingTest, TskvEncodeKeyWithoutDot) {
    logging::LogExtra le;
    le.Extend("http.port.ipv4", "4040");
    LOG_CRITICAL() << "line 1\nline 2" << le;
    EXPECT_THAT(GetStreamString(), testing::HasSubstr("line 1\\nline 2"));
    EXPECT_THAT(GetStreamString(), testing::HasSubstr("http.port.ipv4=4040"));
}

TEST_F(LoggingTest, LogFormat) {
    // Note: this is a golden test. The order and content of tags is stable, which
    // is an implementation detail, but it makes this test possible. If the order
    // or content of tags change, this test should be fixed to reflect the
    // changes.
    constexpr std::string_view kExpectedPattern = R"(tskv\t)"
                                                  R"(timestamp=\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}\.\d{6}\t)"
                                                  R"(level=[A-Z]+\t)"
                                                  R"(module=[\w\d ():./]+\t)"
                                                  R"(foo=bar\t)"
                                                  R"(text=test\n)";
    LOG_CRITICAL() << "test" << logging::LogExtra{{"foo", "bar"}};
    logging::LogFlush();
    EXPECT_TRUE(utils::regex_match(GetStreamString(), utils::regex(kExpectedPattern))) << GetStreamString();

    EXPECT_THAT(GetStreamString(), testing::Not(testing::HasSubstr(" ( /")))
        << "Path shortening for logs stopped working.";
}

TEST_F(LoggingLtsvTest, LogFormatLtsv) {
    // Note: this is a golden test. The order and content of tags is stable, which
    // is an implementation detail, but it makes this test possible. If the order
    // or content of tags change, this test should be fixed to reflect the
    // changes.
    constexpr std::string_view kExpectedPattern = R"(timestamp:\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}\.\d{6}\t)"
                                                  R"(level:[A-Z]+\t)"
                                                  R"(module:[-_\w\d ():./]+\t)"
                                                  R"(foo:bar\t)"
                                                  R"(text:test\n)";
    LOG_CRITICAL() << "test" << logging::LogExtra{{"foo", "bar"}};
    logging::LogFlush();
    EXPECT_TRUE(utils::regex_match(GetStreamString(), utils::regex(kExpectedPattern))) << GetStreamString();
}

TEST_F(LoggingRawTest, LogFormat) {
    // Note: this is a golden test. The order and content of tags is stable, which
    // is an implementation detail, but it makes this test possible. If the order
    // or content of tags change, this test should be fixed to reflect the
    // changes.
    constexpr std::string_view kExpectedPattern = R"(tskv\t)"
                                                  R"(foo=bar\t)"
                                                  R"(text=test\n)";
    LOG_CRITICAL() << "test" << logging::LogExtra{{"foo", "bar"}};
    logging::LogFlush();
    EXPECT_TRUE(utils::regex_match(GetStreamString(), utils::regex(kExpectedPattern))) << GetStreamString();

    EXPECT_THAT(GetStreamString(), testing::Not(testing::HasSubstr(" ( /")))
        << "Path shortening for logs stopped working.";
}

TEST_F(LoggingTest, MemLoggerLogFormat) {
    logging::impl::MemLogger mem_logger;
    mem_logger.ForwardTo(&*GetStreamLogger());
    LOG_CRITICAL_TO(mem_logger) << "test" << logging::LogExtra{{"foo", "bar"}};
    logging::LogFlush();

    const auto str = GetStreamString();
    constexpr std::string_view kTimestamp = "timestamp=";
    EXPECT_EQ(str.find(kTimestamp), str.rfind(kTimestamp)) << str;
}

TEST_F(LoggingTest, FloatingPoint) {
    constexpr float f = 3.1415F;
    EXPECT_EQ(ToStringViaLogging(f), ToStringViaStreams(f));

    constexpr double d = 3.1415;
    EXPECT_EQ(ToStringViaLogging(d), ToStringViaStreams(d));

    constexpr long double ld = 3.1415L;
    EXPECT_EQ(ToStringViaLogging(ld), ToStringViaStreams(ld));
}

TEST_F(LoggingTest, NegativeValue) { EXPECT_EQ(ToStringViaLogging(-1), "-1"); }

TEST_F(LoggingTest, MinValue) {
    constexpr auto val = std::numeric_limits<long long>::min();
    EXPECT_EQ(ToStringViaLogging(val), ToStringViaStreams(val));
}

struct UserStructure {};
logging::LogHelper& operator<<(logging::LogHelper& os, UserStructure /*val*/) {
    os << logging::HexShort{0xFF161300};
    os << '\t';
    void* p = nullptr;
    os << logging::Hex{p};
    return os;
}

TEST_F(LoggingTest, UserStruct) { EXPECT_EQ(ToStringViaLogging(UserStructure{}), "FF161300\\t0x0000000000000000"); }

TEST_F(LoggingTest, Pointer) {
    const auto* const pointer = reinterpret_cast<int*>(0xDEADBEEF);
    EXPECT_EQ(ToStringViaLogging(pointer), "0x00000000DEADBEEF");
}

TEST_F(LoggingTest, NullPointer) {
    const char* const p1 = nullptr;
    EXPECT_EQ(ToStringViaLogging(p1), "(null)");

    const int* const p2 = nullptr;
    EXPECT_EQ(ToStringViaLogging(p2), "(null)");
}

TEST_F(LoggingTest, Decimal) {
    using Dec4 = decimal64::Decimal<4>;
    EXPECT_EQ(ToStringViaLogging(Dec4{"42"}), "42");
    EXPECT_EQ(ToStringViaLogging(Dec4{"12.3"}), "12.3");
}

TEST_F(LoggingTest, PlainException) {
    const std::string what = "test exception";
    EXPECT_EQ(ToStringViaLogging(std::runtime_error(what)), what + " (std::runtime_error)");
}

TEST_F(LoggingTest, TracefulExceptionDebug) {
    SetDefaultLoggerLevel(logging::Level::kDebug);

    LOG_CRITICAL() << utils::TracefulException("traceful exception");

    EXPECT_THAT(GetStreamString(), testing::HasSubstr("traceful exception"))
        << "traceful exception is missing its message";
    EXPECT_THAT(GetStreamString(), testing::HasSubstr("\tstacktrace=")) << "traceful exception is missing its trace";
}

TEST_F(LoggingTest, TracefulExceptionInfo) {
    LOG_CRITICAL() << utils::TracefulException("traceful exception");

    EXPECT_TRUE(LoggedTextContains("traceful exception")) << "traceful exception is missing its message";
    EXPECT_FALSE(LoggedTextContains("\tstacktrace=")) << "traceful exception should not have trace";
}

TEST_F(LoggingTest, AttachedException) {
    SetDefaultLoggerLevel(logging::Level::kDebug);

    try {
        throw utils::impl::AttachTraceToException(std::logic_error("plain exception")) << " with additional info";
    } catch (const std::exception& ex) {
        LOG_CRITICAL() << ex;
    }

    EXPECT_TRUE(LoggedTextContains("plain exception")) << "missing plain exception message";
    EXPECT_TRUE(LoggedTextContains("plain exception with additional info")) << "traceful exception message malformed";
    EXPECT_THAT(GetStreamString(), testing::HasSubstr("\tstacktrace=")) << "traceful exception missing its trace";
}

TEST_F(LoggingTest, IfExpressionWithoutBraces) {
    const bool true_flag = true;
    if (true_flag)
        LOG(logging::Level::kNone) << "test";
    else
        FAIL() << "Logging affected the else statement";

    {
        bool passed = false;
        if (true_flag)
            LOG_LIMITED_CRITICAL() << (passed = true);
        else
            FAIL() << "Logging affected the else statement";
        EXPECT_TRUE(passed);
    }

    {
        bool passed = false;
        if (!true_flag)
            LOG_LIMITED_CRITICAL() << "test";
        else
            passed = true;
        EXPECT_TRUE(passed);
    }

    {
        bool passed = false;
        if (true_flag) LOG_LIMITED_CRITICAL() << (passed = true);
        EXPECT_TRUE(passed);
    }

    {
        bool passed = true;
        if (!true_flag) LOG_LIMITED_CRITICAL() << (passed = false);
        EXPECT_TRUE(passed);
    }
}

TEST_F(LoggingTest, CppModulePath) {
    LOG_CRITICAL();
    logging::LogFlush();
    CheckModulePath(GetStreamString(), "userver/core/src/logging/log_message_test.cpp");
}

TEST_F(LoggingTest, HppModulePath) {
    LoggingHeaderFunction();
    logging::LogFlush();
    CheckModulePath(GetStreamString(), "userver/core/src/logging/log_message_test.hpp");
}

TEST_F(LoggingTest, ExternalModulePath) {
    static constexpr std::string_view kPath = "/somewhere_else/src/test.cpp";

    {
        const logging::LogHelper a(
            logging::GetDefaultLogger(),
            logging::Level::kCritical,
            logging::LogClass::kLog,
            utils::impl::SourceLocation::Custom(__LINE__, kPath, __func__)
        );
    }
    logging::LogFlush();

    CheckModulePath(GetStreamString(), kPath);
}

TEST_F(LoggingTest, LogHelperNullptr) {
    static constexpr std::string_view kPath = "/somewhere_else/src/test.cpp";

    // LogHelper must survive nullptr
    logging::LogHelper(
        logging::LoggerPtr{},
        logging::Level::kCritical,
        logging::LogClass::kLog,
        utils::impl::SourceLocation::Custom(__LINE__, kPath, __func__)
    )
            .AsLvalue()
        << "Test";
    logging::LogFlush();

    EXPECT_EQ(GetStreamString(), "");
}

TEST_F(LoggingTest, LogHelperNullLogger) {
    static constexpr std::string_view kPath = "/somewhere_else/src/test.cpp";

    // logging::impl::DefaultLoggerRef() may return NullLogger
    logging::LogHelper(
        logging::GetNullLogger(),
        logging::Level::kCritical,
        logging::LogClass::kLog,
        utils::impl::SourceLocation::Custom(__LINE__, kPath, __func__)
    )
            .AsLvalue()
        << "Test";
    logging::LogFlush();

    EXPECT_EQ(GetStreamString(), "");
}

TEST_F(LoggingTest, PartialPrefixModulePath) {
    static const std::string kRealPath = __FILE__;
    static const std::string kPath = kRealPath.substr(0, kRealPath.find('/', 1) + 1) + "somewhere_else/src/test.cpp";

    {
        const logging::LogHelper a(
            logging::GetDefaultLogger(),
            logging::Level::kCritical,
            logging::LogClass::kLog,
            utils::impl::SourceLocation::Custom(__LINE__, kPath, __func__)
        );
    }
    logging::LogFlush();

    CheckModulePath(GetStreamString(), kPath);
}

TEST_F(LoggingTest, LogExtraBool) {
    LOG_CRITICAL() << "test" << logging::LogExtra{{"bool_true", true}};
    logging::LogFlush();
    EXPECT_THAT(GetStreamString(), testing::HasSubstr("bool_true=1"));

    ClearLog();

    LOG_CRITICAL() << "test" << logging::LogExtra{{"bool_false", false}};
    logging::LogFlush();
    EXPECT_THAT(GetStreamString(), testing::HasSubstr("bool_false=0"));
}

TEST_F(LoggingTest, LogExtraTAXICOMMON1362) {
    const char* str = reinterpret_cast<const char*>(tskv_test::data_bin);
    const std::string input(str, str + sizeof(tskv_test::data_bin));

    LOG_CRITICAL() << input;
    logging::LogFlush();
    std::string result = GetStreamString();

    ASSERT_GT(result.size(), 1);
    EXPECT_EQ(result.back(), '\n');
    result.pop_back();

    EXPECT_TRUE(result.find(tskv_test::ascii_part) != std::string::npos) << "Result: " << result;

    const auto png_pos = result.find("PNG");
    EXPECT_TRUE(png_pos != std::string::npos) << "Result: " << result;

    EXPECT_EQ(0, std::count(result.begin() + png_pos, result.end(), '\n')) << "Result: " << result;
    EXPECT_EQ(0, std::count(result.begin() + png_pos, result.end(), '\t')) << "Result: " << result;
    EXPECT_EQ(0, std::count(result.begin() + png_pos, result.end(), '\0')) << "Result: " << result;
}

TEST_F(LoggingTest, TAXICOMMON1362) {
    const char* str = reinterpret_cast<const char*>(tskv_test::data_bin);
    std::string input(str, str + sizeof(tskv_test::data_bin));

    LOG_CRITICAL() << logging::LogExtra{{"body", input}};
    logging::LogFlush();
    const std::string result = GetStreamString();

    const auto ascii_pos = result.find(tskv_test::ascii_part);
    EXPECT_TRUE(ascii_pos != std::string::npos) << "Result: " << result;

    const auto body_pos = result.find("body=");
    EXPECT_TRUE(body_pos != std::string::npos) << "Result: " << result;

    EXPECT_EQ(result.substr(body_pos, ascii_pos - body_pos).find_first_of({'\n', '\t', '\0'}), std::string::npos)
        << "Result: " << result;
}

TEST_F(LoggingTest, Ranges) {
    const std::vector<std::set<int>> nested = {{1, 2, 3}, {4}, {5, 6}};
    EXPECT_EQ(ToStringViaLogging(nested), "[[1, 2, 3], [4], [5, 6]]");

    const std::unordered_set<int> set = {42};
    EXPECT_EQ(ToStringViaLogging(set), "[42]");
}

TEST_F(LoggingTest, CustomRanges) {
    struct MyRange {
        std::vector<int> impl;
        auto begin() const { return impl.begin(); }
        auto end() const { return impl.end(); }
    };
    const MyRange range = {{1, 2, 3}};

    EXPECT_EQ(ToStringViaLogging(range), "[1, 2, 3]");
}

TEST_F(LoggingTest, Maps) {
    const std::map<int, std::string> map1 = {{1, "a"}, {2, "b"}, {3, "c"}};
    EXPECT_EQ(ToStringViaLogging(map1), R"([1: "a", 2: "b", 3: "c"])");

    const std::unordered_map<int, std::string> map2 = {{42, "a"}};
    EXPECT_EQ(ToStringViaLogging(map2), R"([42: "a"])");
}

namespace logging {

template <typename T, typename U>
logging::LogHelper& operator<<(logging::LogHelper& lh, const std::pair<T, U>& value) {
    lh << "(" << value.first << ", " << value.second << ")";
    return lh;
}

}  // namespace logging

TEST_F(LoggingTest, CustomMaps) {
    struct MyMap {
        std::vector<std::pair<const std::string, int>> impl;

        using key_type [[maybe_unused]] = std::string;
        using mapped_type [[maybe_unused]] = int;

        auto begin() const { return impl.begin(); }
        auto end() const { return impl.end(); }
    };
    const MyMap map{{{"b", 1}, {"a", 2}}};
    EXPECT_EQ(ToStringViaLogging(map), R"(["b": 1, "a": 2])");

    struct MyPseudoMap {
        std::vector<std::pair<const std::string, int>> impl;

        auto begin() const { return impl.begin(); }
        auto end() const { return impl.end(); }
    };
    const MyPseudoMap pseudo_map{{{"b", 1}, {"a", 2}}};
    EXPECT_EQ(ToStringViaLogging(pseudo_map), R"([(b, 1), (a, 2)])");
}

TEST_F(LoggingTest, RangeOverflow) {
    std::vector<int> range(10000);
    std::iota(range.begin(), range.end(), 0);

    LOG_CRITICAL() << range;
    EXPECT_THAT(LoggedText(), testing::HasSubstr("1850, 1851, ...8148 more"));
}

TEST_F(LoggingTest, ImmediateRangeOverflow) {
    const std::string filler(100000, 'A');
    const std::vector<int> range{42};

    LOG_CRITICAL() << filler << range;
    EXPECT_THAT(LoggedText(), testing::HasSubstr("[...1 more]"));
}

TEST_F(LoggingTest, NestedRangeOverflow) {
    const std::vector<std::vector<std::string>> range{
        {"1", "2", "3"}, {std::string(100000, 'A'), "4", "5"}, {"6", "7"}};

    LOG_CRITICAL() << range;
    EXPECT_THAT(LoggedText(), testing::HasSubstr(R"([["1", "2", "3"], ["AAA)"));
    EXPECT_THAT(LoggedText(), testing::HasSubstr(R"(AAA...", ...2 more], ...1 more])"));
}

TEST_F(LoggingTest, MapOverflow) {
    std::map<int, int> map;
    for (int i = 0; i < 10000; ++i) {
        map.emplace(i, i);
    }

    LOG_CRITICAL() << map;
    EXPECT_THAT(LoggedText(), testing::HasSubstr("[0: 0, 1: 1,"));
    EXPECT_THAT(LoggedText(), testing::HasSubstr("1017: 1017, 1018: 1018, ...8981 more]"));
}

TEST_F(LoggingTest, FilesystemPath) { EXPECT_EQ(ToStringViaLogging(boost::filesystem::path("a/b/c")), R"("a/b/c")"); }

TEST_F(LoggingTest, StringEscaping) {
    const std::vector<std::string> range{"", "A", "\"", "\\", "\n"};
    EXPECT_EQ(ToStringViaLogging(range), R"(["", "A", "\\"", "\\\\", "\n"])");
}

TEST_F(LoggingTest, Json) {
    const auto* const json_str = R"({"a":"b","c":1,"d":0.25,"e":[],"f":{}})";
    EXPECT_EQ(ToStringViaLogging(formats::json::FromString(json_str)), json_str);
}

TEST_F(LoggingTest, LogLimited) {
    EXPECT_EQ(CountLimitedLoggedTimes<1>(), 1);
    EXPECT_EQ(CountLimitedLoggedTimes<2>(), 2);
    EXPECT_EQ(CountLimitedLoggedTimes<3>(), 2);
    EXPECT_EQ(CountLimitedLoggedTimes<4>(), 3);
    EXPECT_EQ(CountLimitedLoggedTimes<5>(), 3);
    EXPECT_EQ(CountLimitedLoggedTimes<6>(), 3);
    EXPECT_EQ(CountLimitedLoggedTimes<7>(), 3);
    EXPECT_EQ(CountLimitedLoggedTimes<8>(), 4);
    EXPECT_EQ(CountLimitedLoggedTimes<1024>(), 11);
}

TEST_F(LoggingTest, LogLimitedDisabled) {
    logging::impl::SetLogLimitedEnable(false);
    EXPECT_EQ(CountLimitedLoggedTimes<1024>(), 1024);
    logging::impl::SetLogLimitedEnable(true);
}

TEST_F(LoggingTest, CustomLoggerLevel) {
    const auto logger_data = MakeNamedStreamLogger("other-logger", logging::Format::kTskv);
    const auto& logger = logger_data.logger;

    // LOG_*_TO() must use its own log level, not default logger's one
    SetDefaultLoggerLevel(logging::Level::kCritical);
    logging::SetLoggerLevel(*logger, logging::Level::kInfo);

    LOG_INFO_TO(*logger) << "test";
    LOG_LIMITED_INFO_TO(*logger) << "mest";
    LOG_DEBUG_TO(*logger) << "tost";
    LOG_LIMITED_DEBUG_TO(*logger) << "most";
    logging::LogFlush(*logger);

    const auto result = logger_data.stream.str();
    EXPECT_THAT(result, testing::HasSubstr("test"));
    EXPECT_THAT(result, testing::HasSubstr("mest"));
    EXPECT_THAT(result, testing::Not(testing::HasSubstr("tost")));
    EXPECT_THAT(result, testing::Not(testing::HasSubstr("most")));
}

TEST_F(LoggingTest, NullLogger) {
    LOG_INFO_TO(logging::GetNullLogger()) << "1";
    logging::GetNullLogger().SetLevel(logging::Level::kTrace);
    LOG_INFO_TO(logging::GetNullLogger()) << "2";
    EXPECT_FALSE(logging::GetNullLogger().ShouldLog(logging::Level::kInfo));

    EXPECT_THAT(GetStreamString(), testing::Not(testing::HasSubstr("text=1")));
    EXPECT_THAT(GetStreamString(), testing::Not(testing::HasSubstr("text=2")));
}

TEST_F(LoggingTest, NullLoggerPtr) {
    auto ptr = logging::MakeNullLogger();
    LOG_INFO_TO(ptr) << "1";
    ptr->SetLevel(logging::Level::kTrace);
    LOG_INFO_TO(ptr) << "2";
    EXPECT_FALSE(ptr->ShouldLog(logging::Level::kInfo));

    EXPECT_THAT(GetStreamString(), testing::Not(testing::HasSubstr("text=1")));
    EXPECT_THAT(GetStreamString(), testing::Not(testing::HasSubstr("text=2")));
}

TEST_F(LoggingTest, Noexceptness) {
    static_assert(noexcept(logging::ShouldLog(logging::Level::kCritical)));
    static_assert(noexcept(logging::impl::Noop{}));
    static_assert(noexcept(logging::GetDefaultLogger()));
    static_assert(noexcept(logging::LogExtra()));
    static_assert(noexcept(logging::LogExtra::Stacktrace()));

    if constexpr (noexcept(std::string_view{"some string"})) {
        EXPECT_TRUE(noexcept(logging::LogHelper(logging::GetNullLogger(), logging::Level::kCritical)));

        const auto logger_ptr = logging::MakeNullLogger();
        EXPECT_TRUE(noexcept(logging::LogHelper(logger_ptr, logging::Level::kCritical)));

        EXPECT_TRUE(noexcept(logging::LogHelper(logging::LoggerPtr{}, logging::Level::kCritical)));

        EXPECT_TRUE(noexcept(std::declval<const logging::impl::StaticLogEntry&>().ShouldNotLog(
            logging::GetDefaultLogger(), logging::Level::kInfo
        )));

        EXPECT_TRUE(noexcept(USERVER_IMPL_LOG_TO(logging::GetNullLogger(), logging::Level::kInfo)));

        EXPECT_TRUE(noexcept(std::declval<logging::LogHelper&>() << "Test"));
        EXPECT_TRUE(noexcept(std::declval<logging::LogHelper&>() << logging::LogExtra::Stacktrace()));
    }
}

USERVER_NAMESPACE_END
